package com.eastcom.dataquality.dv.analysis.extract;

import java.util.concurrent.BlockingQueue;

import com.eastcom.dataquality.core.dao.DaoFactory;
import com.eastcom.dataquality.core.module.Atom_SmoothEvent;
import com.eastcom.dataquality.dv.CollectData;

public abstract class Extractor{
	protected DaoFactory daoFactory;
	
	protected BlockingQueue<Atom_SmoothEvent> eventQueue;
	

	public abstract void process(CollectData collectData);
	
	public DaoFactory getDaoFactory() {
		return daoFactory;
	}

	public void setDaoFactory(DaoFactory daoFactory) {
		this.daoFactory = daoFactory;
	}
	
	public BlockingQueue<Atom_SmoothEvent> getEventQueue() {
		return eventQueue;
	}

	public void setEventQueue(BlockingQueue<Atom_SmoothEvent> eventQueue) {
		this.eventQueue = eventQueue;
	}
}
